package com.songjia.stream.test03;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

import com.songjia.stream.model.Order;

@EnableBinding(OrderProcessor.class)
public class OrderReceiver {

	@StreamListener(OrderProcessor.INPUT_ORDER)
	public void orderTask(Order order) {
		System.out.println("接收到订单消息：" + order);
	}
}
